
import org.apache.spark.{SparkConf, SparkContext}
import spark_base.steam.KafkaConsumer
import utils.WordCount


object App {

  def main(args: Array[String]): Unit = {



//    val url="/home/wxp/tmp/test.log";
//    val wc =new WordCount;
//    wc.f(url);

  }



}
